package com.gitee.wsl.flow.transform.buffer

import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.flow

//fun <T> Flow<T>.chunked(count: Int): Flow<List<T>> = flow {
//    val list = mutableListOf<T>()
//    collect {
//        if (list.size == count) {
//            emit(list.toList())
//            list.clear()
//        } else {
//            list.add(it)
//        }
//    }
//    if (list.isNotEmpty()) {
//        emit(list)
//    }
//}